package org.leiyang.service;

import org.leiyang.common.dtos.OffLineMsgsVO;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.messaging.rsocket.service.RSocketExchange;
import reactor.core.publisher.Mono;

public interface RemoteCallByRSocket {
//    Logger logger = LoggerFactory.getLogger(RemoteCallByRSocket.class);

    /**
     * 将离线消息发送给本地的MsgServer
     */
    @RSocketExchange("localsend")
    Mono<Boolean> sendOffLineMsgsByRS(@Payload OffLineMsgsVO offLineMsgsVO);
}
